// const WebSocket = require('ws')
// import { executeQuery } from './tdengine'
//
// export function createWsServer() {
//   const wss = new WebSocket.Server({ port: 8081 })
//
//   wss.on('connection', (ws) => {
//     console.log('WebSocket client connected')
//
//     ws.on('message', async (message) => {
//       try {
//         console.log('local send message:', message.toString())
//         const { id, type, payload } = JSON.parse(message)
//         const queryType = type.split('|')
//         if (queryType[0] === 'query') {
//           console.log(`Received query sql: ${payload.sql}`)
//
//           // 执行查询
//           const result = await executeQuery(payload.sql)
//           console.log(`Query result........: ${result}`)
//           // 发送查询结果
//           ws.send(
//             JSON.stringify({
//               id,
//               type: type,
//               payload: result
//             })
//           )
//         } else if (queryType[0] === 'insert') {
//         } else if (queryType[0] === 'delete') {
//         }
//       } catch (err) {
//         console.error('Error processing message:', err)
//         ws.send(
//           JSON.stringify({
//             type: 'error',
//             payload: err.message
//           })
//         )
//       }
//     })
//
//     ws.on('close', () => {
//       console.log('WebSocket client disconnected')
//     })
//   })
//
//   console.log('WebSocket server running on port 8081')
//   return wss
// }
